# -*- coding: utf-8 -*-
from utils.operators.external_dag_sensor import ExternalDagSensorAsync
from datetime import timedelta

jms_ods__tab_barscan_taking_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_taking_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_taking_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_warehousing_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_warehousing_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_warehousing_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_send_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_send_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_send_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_arrival_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_arrival_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_arrival_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_unloading_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_unloading_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_unloading_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_bagging_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_bagging_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_bagging_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_loading_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_loading_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_loading_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_deliver_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_deliver_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_deliver_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_sign_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_sign_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_sign_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_collect_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_collect_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_collect_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_other_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_other_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_other_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__yl_oms_oms_waybill_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__yl_oms_oms_waybill_ai_ageing_cusc_hi',
    external_dag_id='jms',
    external_task_id='jms_ods__yl_oms_oms_waybill',
    external_execution_date_time='{{ execution_date | cst_ds }} 00:15:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_reback_transfer_express_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_reback_transfer_express_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_reback_transfer_express_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_barscan_difficult_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_barscan_difficult_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_barscan_difficult_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__tab_end_piece_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__tab_end_piece_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__tab_end_piece_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__yl_oms_interceptorpiece_hi_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_ods__yl_oms_interceptorpiece_hi_ai_ageing_cusc_hi',
    external_dag_id='jms_hi',
    external_task_id='jms_ods__yl_oms_interceptorpiece_hi',
    external_execution_date_time='{{ execution_date | hour_add(11) | cst_hour_ds }}:10:00',
    execution_delta_time_unit='hours',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)

jms_ods__yl_lmdm_sys_staff = ExternalDagSensorAsync(
    task_id='jms_ods__yl_lmdm_sys_staff',
    external_dag_id='jms',
    external_task_id='jms_ods__yl_lmdm_sys_staff',
    external_execution_date_time='{{ execution_date | hour_add(12) | date_add(-1) | cst_ds }} 00:15:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='jarl.huang@jtexpress.com',
)

ai_group__yl_oms_oms_order = ExternalDagSensorAsync(
    task_id='ai_group__yl_oms_oms_order',
    external_dag_id='jms',
    external_task_id='ai_group__yl_oms_oms_order',
    external_execution_date_time='{{ execution_date | hour_add(12) | date_add(-1) | cst_ds }} 00:15:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='jarl.huang@jtexpress.com',
)